// package org.jeecg.modules.message.websocket;
//
// import cn.hutool.core.util.ObjectUtil;
// import lombok.extern.slf4j.Slf4j;
// import org.jeecg.common.base.BaseMap;
// import org.jeecg.common.constant.CommonSendStatus;
// import org.jeecg.common.modules.redis.listener.JeecgRedisListerer;
// import org.springframework.beans.factory.annotation.Autowired;
// import org.springframework.stereotype.Component;
//
// /**
// * 监听消息(采用redis发布订阅方式发送消息)
// */
// @Slf4j
// //@Component
// public class TerminalSocketHandler implements JeecgRedisListerer {
//
//    @Autowired
//    private TerminalWebSocket terminalWebSocket;
//
//    @Override
//    public void onMessage(BaseMap map) {
//        log.info("【SocketHandler消息】Redis Listerer:" + map.toString());
//
//        String terminalId = map.get("terminalId");
//        String message = map.get("message");
//        if (ObjectUtil.isNotEmpty(terminalId)) {
//            terminalWebSocket.pushMessage(terminalId, message);
//            //app端消息推送
//            terminalWebSocket.pushMessage(terminalId+CommonSendStatus.TERMINAL_SESSION_SUFFIX, message);
//        } else {
//            terminalWebSocket.pushMessage(message);
//        }
//
//    }
// }